<?php

include_once('conexionBD.php');

function obtieneMensajes($idTema){
    $i = 0;
    $tabla = null;

    $con = conectarBD();
    $result = mysql_query("SELECT * FROM mensaje M WHERE M.ID_Tema = '$idTema' ORDER BY M.FECHA ASC" , $con);

    if (!$result) {
        die("Error al ejecutar la consulta: " . mysql_error());
    }
    else {
        while ($row = mysql_fetch_array($result)) {
            $tabla[$i] = $row;
            $i++;
        }
    }

    mysql_free_result($result);
    desconectarBD($con);

    return $tabla;
}

function obtieneNumeroMensajes($idTema){
    $i = 0;
    $nMensajes = 0;

    $con = conectarBD();
    $result = mysql_query("SELECT count(*) FROM mensaje M WHERE M.ID_TEMA = '$idTema'", $con);

    if (!$result) {
        die("Error al ejecutar la consulta: " . mysql_error());
    }
    else {
        $nMensajes = mysql_fetch_array($result);
    }

    mysql_free_result($result);
    desconectarBD($con);

    return $nMensajes;
}

function obtieneUsuarioFechaUltimoMensaje($idTema){
    $i = 0;
    $aux = null;

    $con = conectarBD();
    $result = mysql_query("SELECT M.USUARIO,M.FECHA FROM mensaje M WHERE M.FECHA = (SELECT max(ME.FECHA) FROM mensaje ME WHERE ME.ID_TEMA = '$idTema')", $con);

    if (!$result) {
        die("Error al ejecutar la consulta: " . mysql_error());
    }
    else {
        $aux = mysql_fetch_array($result);
    }

    mysql_free_result($result);
    desconectarBD($con);

    return $aux;
}

function insertaMensaje($contenido, $usuario, $idTema) {
    $con = conectarBD();
    
    $sql = "INSERT INTO mensaje (usuario, id_tema, contenido, fecha) VALUES ('$usuario', '$idTema', '$contenido', SYSDATE())";

    if (!mysql_query($sql, $con)) {
        die('Error: ' . mysql_error());
    }

    desconectarBD($con);
}

?>
